package cn.tedu.charging.canal.handler;

import cn.tedu.charging.canal.po.StationCanalPO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import top.javatool.canal.client.annotation.CanalTable;
import top.javatool.canal.client.handler.EntryHandler;
@Component
@Slf4j
//告诉canal,明确表示希望这个处理器 监听的负责的表格charging_station
@CanalTable("charging_station")
public class StationCanalHandler implements EntryHandler<StationCanalPO> {
    @Autowired
    private RedisTemplate redisTemplate;
    //insert 具体处理方案
    @Override
    public void insert(StationCanalPO stationCanalPO){
        log.info("新增了站点:{}",stationCanalPO);
    }
    //delete
    @Override
    public void delete(StationCanalPO stationCanalPO){
        log.info("删除了站点:{}",stationCanalPO);
    }
    //update 传递更新前before(更新哪个字段,before传哪个字段) 更新后的after(全部字段)
    @Override
    public void update(StationCanalPO before, StationCanalPO after){
        log.info("更新了站点:{}",before);
        log.info("更新后:{}",after);
    }
}
